#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2024/5/28 22:21
# @Author : 闫峰
# @File    : mian.py
from utils.rabbitmq.rabbitmq_utils1 import RabbitMq_

if __name__ == '__main__':
    # 创建发送者实例
    sender = RabbitMq_('my_fanout_exchange', 'any_queue', '', mode='broadcast')

    # 发送消息
    message = (1,"@",3,4,5,6)
    sender.send_message(message)

    # 关闭发送者连接
    sender.closeConnection()